package com.heima.kafka.boot.listener;

import com.alibaba.fastjson.JSON;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.common.protocol.Message;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * 消费者的监听类
 */
@Component
public class ConsumerListener {
    /**
     * 监听
     *  @KafkaListener(topics = )
     *  topics属性表示监听的具体的主题，返回值字符串数组类型，也就意味着可以监听多组的主题
     *  比如如果监听一个主题的话，写法 @KafkaListener(topics ="boot-topic" )或者@KafkaListener(topics ={"boot-topic"} )
     *  比如如果监听多个主题的话，写法：@KafkaListener(topics ={"boot-topic","aaaa-topic"} )
     *
     *  注意：监听的方法中的参数是作为获取消息的方式
     */
    @KafkaListener(topics ="stream_get_topic" )
    public void getMessage(ConsumerRecord consumerRecord){
        System.out.println("消息的key:"+consumerRecord.key()+",消息的value:"+consumerRecord.value());
    }
}
